package com.rabbit.mq.handler;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;

import java.io.IOException;

/**
 * @version V1.0.0
 * @ClassName: {@link QueueHandler}
 * @Description: QueueHandler
 * @author: Lanzhou
 * @date: 2021/3/19 9:34
 * @Copyright:2020 All rights reserved.
 */
public interface QueueHandler {

    /**
     * 处理请求
     * @param message
     * @param channel
     * @throws IOException
     */
    void handle(Message message, Channel channel) throws IOException;


}
